package com.example.streamconsumer.stream;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Component;

/**
 * @Author: lihui
 * @Date: 2022-03-23 09:23
 * @Description:
 */
@Component
public interface InputInterface {

    String MSG_INPUT ="msg-input";

    String DEFAULT = "default.message";

    @Input(MSG_INPUT)
    SubscribableChannel receiveMsg();

    @Input(DEFAULT)
    SubscribableChannel defaultInput();
}
